package com.siteseat.crudeq.client;

import java.io.IOException;
import java.util.Set;


public interface SubscriptionConnection extends Connection {
  
  ClientMessage waitNextMessage() throws InterruptedException, IOException;
  
  void startWaitMessage() throws IOException;
  
  void stopWaitMessage() throws IOException, InterruptedException;
 
  
  void subscribe( Set<Integer> queueIds ) throws IOException;
  
  void unsubscribe( Set<Integer> queueIds ) throws IOException;
  
  void unsubscribeAll() throws IOException;
  
}
